package com.carrot.mq.common;

import com.carrot.mq.mqserver.core.BasicProperties;

import java.io.IOException;

/**
 * @author 兴趣使然黄小黄
 * @version 1.0
 * @date 2023/8/25 18:04
 * 收到消息后处理消息需要用到的回调
 */
@FunctionalInterface
public interface Consumer {
    /**
     * 投递, 每次服务器收到消息后来调用, 该方法将消息推送给对应的消费者
     */
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;
}
